package tujie.ch03

import org.apache.spark.{SparkConf, SparkContext}

object RddTest {
  def main(args: Array[String]): Unit = {
    val conf = new SparkConf().setAppName("RddTest").setMaster("local")
    val sc = new SparkContext(conf)

    val classpath = this.getClass().getClassLoader().getResource("").getPath()
    println(classpath)
    val file = sc.textFile(classpath + "data/word-count.txt")
    println(file.partitions.size)
  }

}
